5190174084e45c1d06f35e50c0ee7f1bf38d837d,examples/src/main/java8/org/apache/ignite/examples/MessagingExample.java,MessagingExample,startListening,#ClusterGroup#,102
Before Change
*/
private static void startListening(ClusterGroup prj) throws IgniteException {
// Add ordered message listener.
prj.message().remoteListen(TOPIC.ORDERED, (nodeId, msg) -> {
System.out.println("Received ordered message [msg=" + msg + ", fromNodeId=" + nodeId + ']');
try {
// Projection does not contain local node: ClusterGroup rmtPrj = g.forRemotes();
// So, need to get projection for sender node through entire cluster.
prj.ignite().forNodeId(nodeId).message().send(TOPIC.ORDERED, msg);
}
catch (IgniteException e) {
e.printStackTrace();
}
return true; // Return true to continue listening.
}).get();
// Add unordered message listener.
prj.message().remoteListen(TOPIC.UNORDERED, (nodeId, msg) -> {
After Change
*/
private static void startListening(final Ignite ignite, IgniteMessaging imsg) throws IgniteException {
// Add ordered message listener.
imsg.remoteListen(TOPIC.ORDERED, (nodeId, msg) -> {
System.out.println("Received ordered message [msg=" + msg + ", fromNodeId=" + nodeId + ']');
try {
ignite.message(ignite.cluster().forNodeId(nodeId)).send(TOPIC.ORDERED, msg);
}
catch (IgniteException e) {
e.printStackTrace();
}
return true; // Return true to continue listening.
});
// Add unordered message listener.
imsg.remoteListen(TOPIC.UNORDERED, (nodeId, msg) -> {